package com.ydl.learning.flink.demo.pipeline

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}

/**
 *
 *
 * @author ydl
 * @since 2022/1/7
 */
trait Source[T] extends BaseProcedure {
  protected var streamEnv: StreamExecutionEnvironment = _
  def env(): StreamExecutionEnvironment={
    this.streamEnv
  }

  def init(): DataStream[T]

}
